package com.dukk.espark.apps;


import com.alibaba.fastjson.JSONObject;
import com.dukk.espark.core.Engine;
import com.dukk.espark.core.SparkBase;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;


@Engine(name = "GeoJsonApp")
public class GeoJsonApp extends SparkBase {

    @Override
    public void doAi(JSONObject params) {
        Dataset<Row> jsonDataset = sparkSession.read().json(configKit.getEsparkFilePath());
        jsonDataset.printSchema();
        jsonDataset.show();
    }
}
